package com.example.admin.service;

import com.baomidou.mybatisplus.extension.service.IService;
import com.example.admin.model.Person;
import com.example.admin.result.ResponseResult;
import org.apache.kafka.clients.consumer.ConsumerRecord;

import java.util.List;

public interface ExampleService {

    ResponseResult<String> producerKafkaExample();

//    @KafkaListener(topics = ("${spring.kafka.template.default-topic}") , groupId = ("${spring.kafka.consumer.group-id}"))
    ResponseResult<String> consumerKafkaExample(ConsumerRecord consumerRecord);

    ResponseResult<String> producerRedisExample(List<Person> personList);

    ResponseResult<String> saveSeataAndRedisExample(List<Person> personList);

    ResponseResult<String> savePersonExample(List<Person> personList);

    ResponseResult<List<Person>> queryPersonExample();
}
